package com.tyrone;


import com.tyrone.hephaestus.broker.register.Registry;
import com.tyrone.hephaestus.common.entity.Msg;
import com.tyrone.hephaestus.consumer.Consumer;
import com.tyrone.hephaestus.producer.Producer;
import org.reflections.Reflections;

import java.util.Set;

public class Application {

    public static void main(String[] args) {
        Registry.init();
        Producer producer = new Producer();
        Msg msg = new Msg();
        msg.setContent("good");
        msg.setTopic("test");
        producer.send(msg);
        System.out.printf("通信完成");
    }
}
